fae6f16fa0c5679d5aae1029268f122de4ebd816,vertx-cassandra/src/main/java/com/englishtown/vertx/cassandra/impl/JsonCassandraConfigurator.java,JsonCassandraConfigurator,initPoolingOptions,#JsonObject#,273
Before Change
if (new_connection_threshold_remote != null) {
poolingOptions.setNewConnectionThreshold(HostDistance.REMOTE, new_connection_threshold_remote);
} else {
Integer max_simultaneous_requests_remote = poolingConfig.getInteger("max_simultaneous_requests_remote");
if (max_simultaneous_requests_remote != null) {
poolingOptions.setNewConnectionThreshold(HostDistance.REMOTE, max_simultaneous_requests_remote);
}
After Change
Integer core_connections_per_host_local = poolingConfig.getInteger("core_connections_per_host_local");
Integer core_connections_per_host_remote = poolingConfig.getInteger("core_connections_per_host_remote");
Integer heartbeat_interval_seconds = poolingConfig.getInteger("heartbeat_interval_seconds");
Integer idle_timeout_seconds = poolingConfig.getInteger("idle_timeout_seconds");
Integer max_connections_per_host_local = poolingConfig.getInteger("max_connections_per_host_local");
Integer max_connections_per_host_remote = poolingConfig.getInteger("max_connections_per_host_remote");
Integer max_queue_size = poolingConfig.getInteger("max_queue_size");
Integer max_requests_per_connection_local = poolingConfig.getInteger("max_requests_per_connection_local");
Integer max_requests_per_connection_remote = poolingConfig.getInteger("max_requests_per_connection_remote");
Integer new_connection_threshold_local = poolingConfig.getInteger("new_connection_threshold_local");
Integer new_connection_threshold_remote = poolingConfig.getInteger("new_connection_threshold_remote");